02e5c3cff91f0b2044c9c7c7e7e57017de5f49b8,cdap-hbase-compat-0.98/src/main/java/co/cask/cdap/data2/transaction/queue/coprocessor/hbase98/HBaseQueueRegionObserver.java,HBaseQueueRegionObserver,start,#CoprocessorEnvironment#,78
Before Change
appName = HBaseQueueAdmin.getApplicationName(hTableName);
flowName = HBaseQueueAdmin.getFlowName(hTableName);
conf = env.getConfiguration();
String hbaseNamespacePrefix = nameConverter.getNamespacePrefix(tableDesc);
TableId queueConfigTableId = HBaseQueueAdmin.getConfigTableId(namespaceId);
final String sysConfigTablePrefix = nameConverter.getSysConfigTablePrefix(tableDesc);
txStateCache = new DefaultTransactionStateCacheSupplier(sysConfigTablePrefix, conf).get();
txSnapshotSupplier = new Supplier<TransactionSnapshot>() {
@Override
public TransactionSnapshot get() {
return txStateCache.getLatestState();
}
};
configTableNameBytes = nameConverter.toTableName(hbaseNamespacePrefix, queueConfigTableId).getName();
cConfReader = new CConfigurationReader(conf, sysConfigTablePrefix);
configCache = ConsumerConfigCache.getInstance(conf, configTableNameBytes, cConfReader, txSnapshotSupplier);
}
}
After Change
appName = HBaseQueueAdmin.getApplicationName(hTableName);
flowName = HBaseQueueAdmin.getFlowName(hTableName);
Configuration conf = env.getConfiguration();
String hbaseNamespacePrefix = nameConverter.getNamespacePrefix(tableDesc);
TableId queueConfigTableId = HBaseQueueAdmin.getConfigTableId(namespaceId);
final String sysConfigTablePrefix = nameConverter.getSysConfigTablePrefix(tableDesc);
txStateCache = new DefaultTransactionStateCacheSupplier(sysConfigTablePrefix, conf).get();
txSnapshotSupplier = new Supplier<TransactionSnapshot>() {
@Override
public TransactionSnapshot get() {
return txStateCache.getLatestState();
}
};
configTableName = nameConverter.toTableName(hbaseNamespacePrefix, queueConfigTableId);
cConfReader = new CConfigurationReader(conf, sysConfigTablePrefix);
configCache = createConfigCache(env);
}
}